//package com.company.dcm.server.tcpsocket;
//
//import com.company.dcm.common.SpringBeanUtil;
//import com.company.dcm.server.tcp.TCPService;
//import lombok.extern.slf4j.Slf4j;
//
//import java.io.IOException;
//import java.io.InputStream;
//import java.io.OutputStream;
//import java.net.Socket;
//import java.net.SocketException;
//
//@Slf4j
//public class TCPSocketConnectThread implements Runnable {
//    private Socket socket;
//    private TCPService tcpServer;
//
//    public TCPSocketConnectThread (Socket socket){
//        this.socket = socket;
//        this.tcpServer = SpringBeanUtil.getBean(TCPService.class);
//    }
//
//    @Override
//    public void run() {
//        while (true){
//            try {
//                System.out.println(Thread.currentThread().getName());
//                // 获取输入输出流，用于发送和接收数据
//                InputStream in = socket.getInputStream();
//                OutputStream out = socket.getOutputStream();
//                // 读取客户端发送的数据
//                byte[] buffer = new byte[1024];
//                int len = 0;
//
//                while(len!=-1){
//                    len=in.read(buffer);
//
//                    System.out.println("收到信息：");
//                    for(int i=0;i<len;i++) {
//                        System.out.print(buffer[i]);
//                        System.out.print(" ");
//                    }
//                    System.out.print("\n");
//
//                    if(buffer[5]==51&buffer[7]==29){
//                        byte[] array=new byte[29];
//                        System.arraycopy(buffer, 8, array, 0, 29);
//                        tcpServer.setRT_DeviceInfo(array);
//                    }
//
//                    out.write("Server response".getBytes());
//                }
//                // 关闭资源
//                in.close();
//                out.close();
//            } catch (SocketException e){
//                log.info("连接断开！{}",socket.getRemoteSocketAddress());
//                break;
//            } catch (IOException e) {
//                log.info("输入输出流报错！");
//                break;
//            }
//
//            try {
//                socket.close();
//            } catch (IOException e) {
//                e.printStackTrace();
//            }
//        }
//        System.out.println(Thread.currentThread().getName()+"线程结束");
//    }
//}
